package com.flink.streaming.web.adapter;

import com.flink.streaming.web.enums.YarnStateEnum;

public interface HttpRequestAdapter {

    /**
     * 通过任务名称获取yarn 的appId
     */
    String getAppIdByYarn(String jobName, String queueName);

    /**
     * 通过http杀掉一个任务
     */
    void stopJobByJobId(String appId);


    /**
     * 查询yarn 上某任务状态
     */
    YarnStateEnum getJobStateByJobId(String appId);


}
